package com.zhuanzhuan.youpin.exception;

import com.alibaba.rocketmq.common.message.MessageExt;

/**
 * @author zz.youpin.G_Y
 * @date 2018年6月12日
 * @说明:mq消费异常
 */
public class ConsumeException extends Exception {

    /**
     * 
     */
    private static final long serialVersionUID = 1L;
    private Exception e;
    private MessageExt messageExt;
    private String body;
    private String key;

    public ConsumeException(Exception e, MessageExt messageExt, String body, String key) {
        super();
        this.e = e;
        this.messageExt = messageExt;
        this.body = body;
        this.key = key;
    }
    public ConsumeException() {
        super();
    }
    public ConsumeException(String message, Throwable cause, boolean enableSuppression, boolean writableStackTrace) {
        super(message, cause, enableSuppression, writableStackTrace);
    }
    public ConsumeException(String message, Throwable cause) {
        super(message, cause);
    }
    public ConsumeException(String message) {
        super(message);
    }
    public ConsumeException(Throwable cause) {
        super(cause);
    }
    public Exception getE() {
        return e;
    }
    public ConsumeException setE(Exception e) {
        this.e = e;
        return this;
    }
    public MessageExt getMessageExt() {
        return messageExt;
    }
    public ConsumeException setMessageExt(MessageExt messageExt) {
        this.messageExt = messageExt;
        return this;
    }
    public String getBody() {
        return body;
    }
    public ConsumeException setBody(String body) {
        this.body = body;
        return this;
    }
    public String getKey() {
        return key;
    }
    public ConsumeException setKey(String key) {
        this.key = key;
        return this;
    }

}
